package org.mq.mymq.common.constants;

/**
 * @ClassName BrokerConstants
 * @Description Broker常量
 * @Author jiarong_ye
 * @Date 2025/6/15 16:05
 * @Version 1.0
 */
public class BrokerConstants {
    public static final String MY_MQ_HOME = "MY_MQ_HOME";
    public static final String BASE_COMMIT_LOG_PATH = "/commitlog/";
    public static final String BASE_CONSUMER_QUEUE_PATH = "/consumequeue/";
    public static final String BASE_PROPERTIES_PATH = "/config/broker.properties";
    public static final String SPLIT = "/";
    public static final Integer COMMITLOG_DEFAULT_SIZE = 1024 * 1024; // 1M
    public static final Integer CONSUME_QUEUE_DEFAULT_SIZE = 1024 * 1024;
    public static final Integer DEFAULT_REFRESH_MQ_TOPIC_TIMESTEP = 3;
    public static final Integer DEFAULT_REFRESH_CONSUMER_OFFSET_TIMESTEP = 3;
    public static final int CONSUME_QUEUE_EACH_MSG_SIZE = 12;
    public static final short DEFAULT_MAGIC_NUM = 25621;
}
